/*
 * 文件名：KafkaProducer.java
 * 版权：Copyright by Layne
 * 描述：
 * 修改人：Layne
 * 修改时间：2019年5月17日
 * 跟踪单号：
 * 修改单号：
 * 修改内容：
 */

package top.layne.boot.samples.kafka.producer;

import javax.annotation.Resource;

import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

@Component
public class KafkaProducer {
	@Resource
	private KafkaTemplate<Object, Object> kafkaTemplate;

	public void send(String topic, String key, Object value) {
		System.out.println(">>>>>>Producer:topic:" + topic + ",key:" + key + ",value:" + value);
		kafkaTemplate.send(topic, key, value);
	}

}
